yudao-cloud 开发指南 yudao-cloud 开发指南
      视频教程
        单体版 (opens new window)
        作者博客 (opens new window)
        GitHub (opens new window)
        • 萌新必读

          • 简介
          • 交流群
          • 视频教程
          • 功能列表
          • 快速启动(后端项目)
          • 快速启动(前端项目)
          • 接口文档
          • 技术选型
          • 项目结构
          • 代码热加载
          • 一键改包
          • 删除功能
          • 内网穿透
          • 达梦数据库专属
        • 后端手册

          • 新建服务
          • 代码生成【单表】(新增功能)
          • 代码生成【主子表】
          • 代码生成(树表)
          • 功能权限
          • 数据权限
          • 用户体系
          • 三方登录
          • OAuth 2.0(SSO 单点登录)
          • SaaS 多租户【字段隔离】
          • SaaS 多租户【数据库隔离】
          • WebSocket 实时通信
          • 异常处理(错误码)
          • 参数校验
          • 分页实现
          • VO 对象转换、数据翻译
          • 文件存储(上传下载)
          • Excel 导入导出
          • 操作日志、访问日志、异常日志
          • MyBatis 数据库
          • MyBatis 联表&分页查询
          • 多数据源(读写分离)
          • Redis 缓存
          • 本地缓存
          • 异步任务
          • 分布式锁
          • 幂等性(防重复提交)
          • 请求限流(RateLimiter)
          • 单元测试
          • 验证码
          • 工具类 Util
          • 数据库文档
        • 微服务手册

          • 微服务调试(必读)
          • 注册中心 Nacos
          • 配置中心 Nacos
          • 服务网关 Spring Cloud Gateway
          • 服务调用 Feign
            • 定时任务 XXL Job
            • 消息队列(内存)
            • 消息队列(Redis)
            • 消息队列(RocketMQ)
            • 消息队列(RabbitMQ)
            • 消息队列(Kafka)
            • 消息队列(Cloud)
            • 分布式事务 Seata
            • 服务保障 Sentinel
          • 工作流手册

            • 工作流演示
            • 功能开启
            • 工作流(达梦适配)
            • 审批接入(流程表单)
            • 审批接入(业务表单)
            • 流程设计器(BPMN)
            • 流程设计器(钉钉、飞书)
            • 选择审批人、发起人自选
            • 会签、或签、依次审批
            • 流程发起、取消、重新发起
            • 审批通过、不通过、驳回
            • 审批加签、减签
            • 审批转办、委派、抄送
            • 执行监听器、任务监听器
            • 流程表达式
            • 流程审批通知
          • 大屏手册

            • 报表设计器
            • 大屏设计器
          • 支付手册

            • 功能开启
            • 支付宝支付接入
            • 微信公众号支付接入
            • 微信小程序支付接入
            • 支付宝、微信退款接入
          • 会员手册

            • 功能开启
            • 微信公众号登录
            • 微信小程序登录
            • 会员用户、标签、分组
            • 会员等级、积分、签到
          • 商城手册

            • 商城演示
            • 功能开启
            • 商城装修
            • 【商品】商品分类
            • 【商品】商品属性
            • 【商品】商品 SPU 与 SKU
            • 【商品】商品评价
            • 【交易】购物车
            • 【交易】交易订单
            • 【交易】售后退款
            • 【交易】快递发货
            • 【交易】门店自提
            • 【交易】分销返佣
            • 【营销】优惠劵
            • 【营销】拼团活动
            • 【营销】秒杀活动
            • 【营销】砍价活动
            • 【营销】满减送
            • 【营销】限时折扣
            • 【营销】内容管理
            • 【统计】会员、商品、交易统计
          • ERP手册

            • ERP 演示
            • 功能开启
            • 【产品】产品信息、分类、单位
            • 【库存】产品库存、库存明细
            • 【库存】其它入库、其它出库
            • 【库存】库存调拨、库存盘点
            • 【采购】采购订单、入库、退货
            • 【销售】销售订单、出库、退货
            • 【财务】采购付款、销售收款
          • CRM手册

            • CRM 演示
            • 功能开启
            • 【线索】线索管理
            • 【客户】客户管理、公海客户
            • 【商机】商机管理、商机状态
            • 【合同】合同管理、合同提醒
            • 【回款】回款管理、回款计划
            • 【产品】产品管理、产品分类
            • 【通用】数据权限
            • 【通用】跟进记录、待办事项
          • 公众号手册

            • 功能开启
            • 公众号接入
            • 公众号粉丝
            • 公众号标签
            • 公众号消息
            • 自动回复
            • 公众号菜单
            • 公众号素材
            • 公众号图文
            • 公众号统计
          • 系统手册

            • 短信配置
            • 邮件配置
            • 站内信配置
            • 数据脱敏
            • 敏感词
            • 地区 & IP 库
          • 运维手册

            • 开发环境
            • Linux 部署
            • Docker 部署
            • Jenkins 部署
            • HTTPS 证书
            • 服务监控
          • 前端手册 Vue 3.x

            • 开发规范
            • 菜单路由
            • Icon 图标
            • 字典数据
            • 系统组件
            • 通用方法
            • 配置读取
            • CRUD 组件
            • 国际化
            • IDE 调试
            • 代码格式化
          • 前端手册 Vue 2.x

            • 开发规范
            • 菜单路由
            • Icon 图标
            • 字典数据
            • 系统组件
            • 通用方法
            • 配置读取
          • 更新日志

            • 【v2.1.0】开发中
            • 【v2.0.1】2024-03-01
            • 【v2.0.0】2024-01-26
            • 【v1.9.0】2023-12-01
            • 【v1.8.3】2023-10-24
          • 开发指南
          • 微服务手册
          芋道源码
          2022-12-31
          目录
          1. RPC 使用规约
          1.1 API 前缀
          1.2 API 权限
          1.3 API 全局返回
          1.4 用户传递
          2. 如何定义一个 API 接口
          2.1 服务提供者
          2.2 服务消费者

          服务调用 Feign

          yudao-spring-boot-starter-rpc (opens new window) 技术组件,基于 Feign 实现服务之间的调用。

          为什么不使用 Dubbo 呢?

          Feign 通用性更强,学习成本更低,对于绝大多数场景,都能够很好的满足需求。虽然 Dubbo 提供的性能更强,特性更全,但都是非必须的。

          目前国内 95% 左右都是采用 Feign,而 Dubbo 的使用率只有 5% 左右。所以,我们也选择了 Feign。

          如果你对 Feign 了解较少,可以阅读 《芋道 Spring Cloud 声明式调用 Feign 入门》 (opens new window) 系统学习。

          # 1. RPC 使用规约

          本小节,我们来讲解下项目中 RPC 使用的规约。

          # 1.1 API 前缀

          API 使用 HTTP 协议,所有的 API 前缀,都以 /rpc-api (opens new window) 开头,方便做统一的全局处理。

          # 1.2 API 权限

          服务之间的调用,不需要进行权限校验,所以需要在每个服务的 SecurityConfiguration 权限配置类中,添加如下配置:

          // RPC 服务的安全配置
          registry.antMatchers(ApiConstants.PREFIX + "/**").permitAll();
          

          # 1.3 API 全局返回

          所有 API 接口返回使用 CommonResult (opens new window) 返回,和前端 RESTful API 保持统一。例如说:

          public interface DeptApi {
          
              @GetMapping(PREFIX + "/get")
              @Operation(summary = "获得部门信息")
              @Parameter(name = "id", description = "部门编号", required = true, example = "1024")
              CommonResult<DeptRespDTO> getDept(@RequestParam("id") Long id);
              
          }
          

          # 1.4 用户传递

          服务调用时,已经封装 Feign 将用户信息通过 HTTP 请求头 login-user 传递,通过 LoginUserRequestInterceptor (opens new window) 类实现。

          这样,被调用服务,可以通过 SecurityFrameworkUtils 获取到用户信息,例如说:

          • #getLoginUser() 方法,获取当前用户。
          • #getLoginUserId() 方法,获取当前用户编号。

          # 2. 如何定义一个 API 接口

          本小节,我们来讲解下如何定义一个 API 接口。以 AdminUserApi 提供的 getUser 接口来举例子。

          # 2.1 服务提供者

          AdminUserApi 由 system-server 服务所提供。

          # 2.1.1 ApiConstants

          在 yudao-module-system-api 模块,创建 ApiConstants (opens new window) 类,定义 API 相关的枚举。代码如下:

          public class ApiConstants {
          
              /**
               * 服务名
               *
               * 注意,需要保证和 spring.application.name 保持一致
               */
              public static final String NAME = "system-server";
          
              public static final String PREFIX = RpcConstants.RPC_API_PREFIX +  "/system";
          
              public static final String VERSION = "1.0.0";
          
          }
          

          # 2.1.2 AdminUserApi

          在 yudao-module-system-api 模块,创建 AdminUserApi (opens new window) 类,定义 API 接口。代码如下:

          @FeignClient(name = ApiConstants.NAME) // ① @FeignClient 注解
          @Tag(name = "RPC 服务 - 管理员用户") // ② Swagger 接口文档
          public interface AdminUserApi {
          
              String PREFIX = ApiConstants.PREFIX + "/user";
          
              @GetMapping(PREFIX + "/get") // ③ Spring MVC 接口注解
              @Operation(summary = "通过用户 ID 查询用户")  // ② Swagger 接口文档
              @Parameter(name = "id", description = "部门编号", required = true, example = "1024") // ② Swagger 接口文档
              CommonResult<AdminUserRespDTO> getUser(@RequestParam("id") Long id);
              
          }
          

          另外,需要创建 AdminUserRespDTO (opens new window) 类,定义用户 Response DTO。代码如下:

          @Data
          public class AdminUserRespDTO {
          
              /**
               * 用户ID
               */
              private Long id;
              /**
               * 用户昵称
               */
              private String nickname;
              /**
               * 帐号状态
               *
               * 枚举 {@link CommonStatusEnum}
               */
              private Integer status;
          
              /**
               * 部门ID
               */
              private Long deptId;
              /**
               * 岗位编号数组
               */
              private Set<Long> postIds;
              /**
               * 手机号码
               */
              private String mobile;
          
          }
          

          # 2.1.3 AdminUserRpcImpl

          在 yudao-module-system-biz 模块,创建 AdminUserRpcImpl (opens new window) 类,实现 API 接口。代码如下:

          @RestController // 提供 RESTful API 接口,给 Feign 调用
          @Validated
          public class AdminUserApiImpl implements AdminUserApi {
          
              @Resource
              private AdminUserService userService;
          
              @Override
              public CommonResult<AdminUserRespDTO> getUser(Long id) {
                  AdminUserDO user = userService.getUser(id);
                  return success(UserConvert.INSTANCE.convert4(user));
              }
              
          }
          

          # 2.2 服务消费者

          bpm-server 服务,调用了 AdminUserApi 接口。

          # 2.2.1 引入依赖

          在 yudao-module-bpm-biz 模块的 pom.xml (opens new window),引入 yudao-module-system-api 模块的依赖。代码如下:

          <dependency>
              <groupId>cn.iocoder.cloud</groupId>
              <artifactId>yudao-module-system-api</artifactId>
              <version>${revision}</version>
          </dependency>
          

          # 2.2.2 引用 API

          在 yudao-module-bpm-biz 模块,创建 RpcConfiguration (opens new window) 配置类,注入 AdminUserApi 接口。代码如下:

          @Configuration(proxyBeanMethods = false)
          @EnableFeignClients(clients = {AdminUserApi.class.class})
          public class RpcConfiguration {
          }
          

          # 2.2.3 调用 API

          例如说,BpmTaskServiceImpl (opens new window) 调用了 AdminUserApi 接口,代码如下:

          @Service
          public class BpmTaskServiceImpl implements BpmTaskService {
          
              @Resource
              private AdminUserApi adminUserApi;
          
              @Override
              public void updateTaskExtAssign(Task task) {
                  // ... 省略非关键代码
                  AdminUserRespDTO startUser = adminUserApi.getUser(id).getCheckedData();
              }
          }
          
          服务网关 Spring Cloud Gateway
          定时任务 XXL Job

          ← 服务网关 Spring Cloud Gateway 定时任务 XXL Job→

          Theme by Vdoing | Copyright © 2019-2024 芋道源码 | MIT License
            ×